package com.tyjt.common.mqtt.config;

import org.eclipse.paho.client.mqttv3.MqttMessage;

/**
 *
 */
public interface DataHandler {

    /**
     * 数据处理
     *
     * @param message
     * @throws Exception
     */
    void handle(String topic,MqttMessage message) throws Exception;
}
